package chapter9;

import com.alibaba.fastjson.JSON;
import redis.clients.jedis.Jedis;

import java.util.HashMap;

public class Publisher {
    /**
     * 主函数入口
     *
     * @param args 命令行参数，本程序未使用
     */
    public static void main(String[] args) {
        // 创建一个HashMap对象用于存储订单信息
        HashMap<String, String> order = new HashMap<>();
        // 添加订单ID
        order.put("id", "1");
        // 添加订单所有者
        order.put("owner", "Farb");
        // 添加订单金额
        order.put("amount", "10000");

        // 将订单信息转换为JSON字符串格式
        String jsonString = JSON.toJSONString(order);

        // 创建Jedis对象，连接本地Redis服务器
        Jedis jedis = new Jedis("127.0.0.1", 6379);
        // 发布JSON字符串到指定的Redis频道上
        jedis.publish("MQChannel", jsonString);
    }
}
